package com.mtf.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.mtf.entity.MtfRocketmqLog;

/**
 * @Description: mtf_rocketmq_log
 * @Author: jeecg-boot
 * @Date:   2024-01-19
 * @Version: V1.0
 */
public interface IMtfRocketmqLogService extends IService<MtfRocketmqLog> {

    /**
     * @Description: 根据msg_id查询消息记录
     * @param identity
     * @return com.mtf.entity.MtfRocketmqLog
     */
    MtfRocketmqLog selectRocketMqLogByMsgId(String identity);

    /**
     * @Description: 订单创建成功，更新消息状态为”消费完成“
     * @param identity
     * @return void
     */
    void updateRocketMqLogMsgStatusByMsgId(String identity);

    /**
     * @Description: 根据identity删除对应的消息记录
     * @param identity
     * @return void
     */
    void deleteRocketMqLogByMsgId(String identity);
}
